From 22c5e3dbbd31d0babcc4e38b6da5e013bb1efcd1 Mon Sep 17 00:00:00 2001
From: Jeroen van der Heijden <jeroen@transceptor.technology>
Date: Tue, 27 Mar 2018 11:27:07 +0200
Subject: [PATCH] add fflush

---
 src/siri/db/shard.c | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/src/siri/db/shard.c b/src/siri/db/shard.c
index cd76ffd0..03fc0d77 100644
--- a/src/siri/db/shard.c
+++ b/src/siri/db/shard.c
@@ -21,6 +21,7 @@
 #include <siri/db/series.h>
 #include <siri/db/shard.h>
 #include <siri/db/shards.h>
+#include <siri/db/points.h>
 #include <siri/optimize.h>
 #include <siri/err.h>
 #include <siri/file/pointer.h>
@@ -586,7 +587,8 @@ size_t siridb_shard_write_points(
 
     long int rc = fwrite(cdata, dsize, 1, fp);
     free(cdata);
-    if (rc != 1)
+
+    if (rc != 1 || fflush(fp))
     {
         ERR_FILE
         log_critical("Cannot write points to file '%s'", shard->fn);
-- 
2.30.2